package com.xzkj.rx.thread.utils;

import io.reactivex.disposables.Disposable;

/**
 * @author: liujie
 * @date: 2021/12/13 下午3:08
 * @description: 间隔发送消息到ui线程接口
 */
public abstract class RxInterval {
    Disposable disposable = null;

    /**
     * 回调到主线程中
     * @param t
     * @param disposable
     */
    public abstract void onUi(Long t, Disposable disposable);

    public void setDisposable(Disposable disposable) {
        this.disposable = disposable;
    }
}
